package com.corn.kafka.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * @author : Jim Wu
 * @version 1.0
 * @function :
 * @since : 2022/7/4 15:03
 */
@Configuration
@Slf4j
public class KafkaSpringBootListener {

    @KafkaListener(topics = "test_topic")
    public void consume(String msg) {
        log.info("接受消息:{}", msg);
    }
}
